package com.example.util.queue;

import javax.jms.Destination;

import org.apache.activemq.command.ActiveMQQueue;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.jms.core.JmsMessagingTemplate;
import org.springframework.stereotype.Service;
/**
 * ActiveMq工具类（已完成）
* @ClassName: QueueActiveMq    
* @Description:     
* @author xzx   
* @date 2018年3月6日 下午6:09:03    
*
 */
@Service
public class QueueActiveMq {
	
	  @Autowired // 也可以注入JmsTemplate，JmsMessagingTemplate对JmsTemplate进行了封装  
	  private JmsMessagingTemplate jmsTemplate;
	  
	    public void sendMessage(String mqQueue, Object message){ 
	    	Destination destination = new ActiveMQQueue(mqQueue);  
	        jmsTemplate.convertAndSend(destination, message);  
	    }  
}
